package com.wondertek.poms.sync.mqListener;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.wondertek.poms.common.constant.Constants;
import com.wondertek.poms.sync.manager.StartProcess;

@Component
@RabbitListener(queues = Constants.QUEUE_NEW_POMS_SYNC)
public class SyncContentListener {
    @Autowired
    private StartProcess startProcess;

    /**
     * <p><b>Title:</b> receiveContentTopic</p>
     * <p><b>Description:</b> 内容快速同步消息队列</p>
     *
     * @param message
     * @author douzi
     */
    @RabbitHandler
    public void receiveContentTopic(String message) {
    	startProcess.fastProcess(message);
    }
}
